package com.woniuxy.rabbitmq.consumeerconfirm.auth;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * @author: 15489  <br/>
 * Date: 2022/4/2:11:59  <br/>
 * Description:
 */

public class AuthProducter {
    public static void main(String[] args) throws IOException, TimeoutException {
//        1:创建工厂:创建rabbitmq的连接对象
        ConnectionFactory factory=new ConnectionFactory();
//        2:设置连接参数
        factory.setHost("192.168.58.128"); //ip
        factory.setPort(5672);             //端口
        factory.setUsername("admin");       //账号
        factory.setPassword("admin");       //密码
        factory.setVirtualHost("/test");   // 虚拟机名字
//        3:创建连接
        Connection connection=factory.newConnection();
        System.out.println(connection);

//        4:发消息


//        4.1 创建一个通道
        Channel channel = connection.createChannel();


//        设置 消息队列的预取值 消费者每一次获取消息的个数


//        5:向消息队列发送消息 如果消息队列不存在 侧创建消息队列 然后发送消息 如果存在直接发送消息

        channel.queueDeclare("aaa",true,false,false,null);
//          6：发送消息
        for (int i=0;i<10;i++){
            channel.basicPublish("","aaa",null,"hell ".getBytes());
        }

//        关闭连接
        connection.close();
    }
}
